4a0f076d3605333a4d3030e6781b012bf7c4b68b,mule/src/test/java/org/mule/test/util/concurrent/WaitPolicyTestCase.java,WaitPolicyTestCase,testWaitPolicyWithTimeoutFailure,#,121
Before Change
// expected
}
_executor.awaitTermination(3000, TimeUnit.MILLISECONDS);
assertSame(s3, policy._lastRejected);
assertEquals(0, _activeThreads);
After Change
assertEquals(RejectedExecutionException.class, threadFailure.getValue().getClass());
_executor.shutdown();
boolean allFinished = _executor.awaitTermination(2500, TimeUnit.MILLISECONDS);
assertTrue(allFinished);
assertSame(s3, policy.lastRejectedRunnable());
assertEquals(0, _activeTasks.get());